package com.ysg.bus;

import android.util.Log;
import com.ysg.utils.YToastUtil;
import io.reactivex.functions.Consumer;
public class RxBusErrorConsumer implements Consumer<Throwable> {
    @Override
    public void accept(Throwable throwable) throws Exception {
        throwable.printStackTrace();
        Log.e("RxBusErrorConsumer", throwable.getMessage());
        YToastUtil.showShort("RxBus:throwable:" + throwable.getMessage());
    }
}
